package com.budwk.app.common.rocketmq.rmqmsg;

import com.budwk.app.common.rocketmq.annotation.RMQConsumer;
import com.budwk.app.common.rocketmq.rmq.RMQConsumerListener;
import org.nutz.ioc.loader.annotation.IocBean;

import java.nio.charset.StandardCharsets;

/**
 * @desc: 方法描述
 * @Author: laoschiang
 * @Date: 2023/7/4 14:54
 * @info:
 */
@IocBean
@RMQConsumer(topic = "MyTopicTest", consumerGroup = "ConsumerGroup1", tag = "TAG1")
public class ConsumerExample implements RMQConsumerListener {

    @Override
    public void onMessage(byte[] message) {
        System.out.println("ConsumerExample1 监听到消息==>  " + new String(message, StandardCharsets.UTF_8));
    }
}
